const mysql = require('mysql');

// 创建数据库连接池
const pool = mysql.createPool({
  host: 'localhost', // 数据库服务器主机名
  user: 'root', // 数据库用户名
  password: '326800', // 数据库密码
  database: 'greenheart' // 数据库名称
});

// 导出查询方法
module.exports = {
  query: function (sql, params, callback) {
    // 从连接池获取一个连接
    pool.getConnection((error, connection) => {
      if (error) {
        console.error('数据库连接错误！', error);
        return callback(error, null);
      }

      // 执行查询
      connection.query(sql, params, (error, results) => {
        // 释放连接回连接池
        connection.release();

        if (error) {
          console.error('查询出现错误！', error);
          return callback(error, null);
        }

        callback(null, results);
      });
    });
  }
};